package rxclass;

import com.kenai.jaffl.struct.Struct;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
import org.apache.poi.ss.formula.functions.T;

import java.util.HashSet;
import java.util.Set;

public abstract class RowSetObserver<T> extends TableObserver<T> {

    private Set<String> set = new HashSet<String>();
    public RowSetObserver(long start) {
        super(start);
    }

    public RowSetObserver(long start, String info) {
        super(start, info);
    }

    @Override
    public void onSubscribe(Disposable d) {

    }

    public boolean multi(String key)
    {
        if (set.contains(key))
        {
            return true;
        }else
        {
            set.add(key);
            return false;
        }
    }

    @Override
    public void onError(Throwable e) {

    }

    @Override
    public void onComplete() {

    }
}
